package cn.com.bluemoon.bd.flink.runner;

import org.apache.flink.table.api.bridge.java.StreamTableEnvironment;

public abstract class AbstractProcessor {

    protected StreamTableEnvironment tableEnv;

    public AbstractProcessor(StreamTableEnvironment tableEnv) {
        this.tableEnv = tableEnv;
    }

    public abstract void process() throws Exception;
}
